package com.yfbao.poll.demo.service;



import com.yfbao.poll.demo.message.BasePollMessage;
import com.yfbao.poll.demo.model.BasePoll;

import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/**
 * 轮询相关缓存和静态变量定义类
 */
public class PollingCache {


    //key: loginName+MsgType    value: 消息列表
    public static Map<String, List<BasePollMessage>> getUserMessageCacheMap() {
        return userMessageCacheMap;
    }


    public static Map<String, List<BasePoll>> getAllWebMap() {
        return allWebMap;
    }

    //用户消息缓存，按照Map<username+msgType,List<message>> 的方式存储
    private static final Map<String, List<BasePollMessage>> userMessageCacheMap = new ConcurrentHashMap<>();

    //保存异步轮询轮询的请求（目前设计只支持同一用户单个客户端模式）
    private static final Map<String, List<BasePoll>> allWebMap = new ConcurrentHashMap<>();



}
